package com.woniuxy.mq.controller;
import com.woniuxy.common.result.Result;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;

/**
 * @author yellow Doctor
 * @date 2025-03-26
 * @desc 蜗牛创想：www.woniuxy.com
 */
@RestController
@RequestMapping("msg")
public class MessageController {
//    /**
//     * 消息发送模板
//     */
//    @Autowired
//    private RabbitTemplate rabbitTemplate;
//
//    @GetMapping("/send")
//    public ResponseEntity<String> sendEmail(String address) {
//        //消息
//        String context = "中奖了500w, 5分钟之后领取！";
//
//        // 发送消息到RabbitMQ队列中 参数1：队列名称 参数2：消息内容
//        rabbitTemplate.convertAndSend("msg.queue", context);
//
//        return ResponseEntity.ok("消息发送成功");
//    }
//
//    @GetMapping("/sendObj")
//    public ResponseEntity<String> sendObj() {
//
//        Result result = new Result();
//        result.setCode(3067);
//        result.setMessage("中彩票5000w");
//
//        // 发送消息到RabbitMQ队列中 参数1：队列名称 参数2：消息内容
//        rabbitTemplate.convertAndSend("obj.queue", result);
//
//        return ResponseEntity.ok("消息发送成功");
//    }
//
//    @GetMapping("/sendMsg")
//    public ResponseEntity<String> sendMsg(String msg) {
//
//        // 发送消息到RabbitMQ队列中 参数1：队列名称 参数2：消息内容
//        rabbitTemplate.convertAndSend("simple.queue", msg);
//
//        return ResponseEntity.ok("简单消息发送成功 ===");
//    }
}
